package com.wicket.okrapp.biz.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.wicket.okrapp.biz.service.dto.common.MemoryBusinessDataDto;
import com.wicket.okrapp.biz.service.dto.common.OutputBusinessDataDto;
import com.wicket.okrapp.biz.service.dto.req.*;
import com.wicket.okrapp.biz.service.dto.res.*;
import com.wicket.okrapp.integration.dto.AddMemoryBusinessDataComRespDto;
import org.apache.skywalking.apm.toolkit.trace.Tag;
import org.apache.skywalking.apm.toolkit.trace.Tags;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import com.wicket.okrapp.common.util.RedisUtil;
import com.wicket.okrapp.common.exception.BizException;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;

import java.util.stream.Collectors;
import com.wicket.okrapp.base.service.MOmsVirtualOrgMemberService;
import com.wicket.okrapp.common.exception.Assert;
import com.wicket.okrapp.biz.service.nb.NbInterfaceMode;
import com.wicket.okrcomponent.integration.dto.CurrentCycleDto;
import com.wicket.okrapp.biz.service.dto.common.BusinessDataSetDto;
import com.wicket.okrapp.biz.service.dto.common.MemoryBusinessResDataDto;
import com.wicket.okrapp.base.service.MSpaceService;
import com.wicket.okrapp.base.service.MOmsTaskService;

/**
 * @author ：
 * @date ：
 *
 *
 * @version 1.0
 */
@Service
public class InterfaceModeServiceImpl implements com.wicket.okrapp.biz.service.InterfaceModeService {
    @Resource
    private RedisUtil redisUtil;
@Resource
  private MOmsVirtualOrgMemberService mOmsVirtualOrgMemberService;
@Resource
  private NbInterfaceMode nbInterfaceMode;
@Resource
  private MSpaceService mSpaceService;
@Resource
  private MOmsTaskService mOmsTaskService;
//@Resource
 //private MCustomFields4Service mCustomFields4Service;
//@Resource
 //private MCustomFields3Service mCustomFields3Service;
//@Resource
 //private MCustomFields2Service mCustomFields2Service;
/**
   * D3判断高中基层步骤值等(公共)[4622]
   * gen by moon at 6/23/2023, 5:31:51 AM
   */
  @Trace(operationName = "D3判断高中基层步骤值等(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public JudgeResetTopMidStepValueComRespDto judgeResetTopMidStepValueCom(JudgeResetTopMidStepValueComReqDto reqDto){
    
      
      ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_2 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_4 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_6 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_8 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_10 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_12 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_14 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_16 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_18 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_20 =null;
ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_22 =null;
//virtualUsage M3判断进入房间，出参步骤与检查项值  16640
      //ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq=new ImplementBizConstructAccessParameterFieldReqDto();
  if(reqDto!=null){
      receptionServiceReq.setStepRoomValue(reqDto.getStepRoomValue());//SimpleFieldAssign//sourceId:335880_1_16640
receptionServiceReq.setBatchOperateScene(reqDto.getBatchOperateScene());//SimpleFieldAssign//sourceId:340196_1_16640
    }
  
    /*M3判断进入房间，出参步骤与检查项值[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getStepRoomValue(),"D3判断高中基层步骤值等(公共)-M3判断进入房间，出参步骤与检查项值-进入步骤房间值不能为空",false);
Assert.isNull(receptionServiceReq.getBatchOperateScene(),"D3判断高中基层步骤值等(公共)-M3判断进入房间，出参步骤与检查项值-高/中/基层操作场景不能为空",false);
      receptionServiceRes = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq);
      
      
      
if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("COMPILE_TARGET_TASK_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("TOP"))) {
        //if((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 编制目标任务房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 高层))  16641
        
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_1 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_1=new ImplementBizConstructAccessParameterFieldReqDto();
receptionServiceReq_1.setStepNameCode("COMPILE_TARGET_TASK");//CUSTOM_CONVENTION//sourceId:336232_1_16642
  
    /*M3进入高层编制目标任务房间（高层）[4518]  用于特殊方法接收上游入参。 */
Assert.isNull(receptionServiceReq_1.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入高层编制目标任务房间（高层）-步骤编码不能为空",false);
      receptionServiceRes_1 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_1);
      
      
      receptionServiceRes_2 = receptionServiceRes_1;
//processBranchName:正常结束 ,processBranchId:16647
        
      }
else if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("DEPT_TARGET_WEIGHT_SET_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("TOP"))){
       //elseif((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 部门目标权重设置房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 高层))  16648
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_3 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_2=new ImplementBizConstructAccessParameterFieldReqDto();
receptionServiceReq_2.setStepNameCode("DEPT_TARGET_WEIGHT_SET");//CUSTOM_CONVENTION//sourceId:336234_1_16649
  
    /*M3进入部门目标权重设置房间（高层）[4518]  用于特殊方法接收上游入参。 */
Assert.isNull(receptionServiceReq_2.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入部门目标权重设置房间（高层）-步骤编码不能为空",false);
      receptionServiceRes_3 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_2);
      
      
      receptionServiceRes_4 = receptionServiceRes_3;
//processBranchName:正常结束 ,processBranchId:16650
        
    }
else if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("LEAD_TARGET_ARRANGE_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("MID"))){
       //elseif((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 牵头目标安排房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 中层))  16651
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_5 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_3=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_3.setCheckItemCode("LEAD_TARGET_TASK_ARRANGE_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:336152_1_16653
receptionServiceReq_3.setDiviCheckItemCode("DEPT_TARGET_TASK_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:336185_1_16653
receptionServiceReq_3.setStepNameCode("LEAD_TARGET_ARRANGE");//CUSTOM_CONVENTION//sourceId:336236_1_16653
  
    /*M3进入牵头目标安排房间（中层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_3.getCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入牵头目标安排房间（中层）-检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_3.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入牵头目标安排房间（中层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_3.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入牵头目标安排房间（中层）-步骤编码不能为空",false);
      receptionServiceRes_5 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_3);
      
      
      receptionServiceRes_6 = receptionServiceRes_5;
//processBranchName:正常结束 ,processBranchId:16654
        
    }
else if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("EXECUTE_TARGET_ARRANGE_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("MID"))){
       //elseif((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 执行目标安排房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 中层))  16655
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_7 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_4=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_4.setCheckItemCode("PERFORM_TARGET_TASK_ARRANGE_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:336153_1_16657
receptionServiceReq_4.setDiviCheckItemCode("DEPT_TARGET_TASK_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:336187_1_16657
receptionServiceReq_4.setStepNameCode("EXECUTE_TARGET_ARRANGE");//CUSTOM_CONVENTION//sourceId:336238_1_16657
  
    /*M3进入执行目标安排房间（中层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_4.getCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入执行目标安排房间（中层）-检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_4.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入执行目标安排房间（中层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_4.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入执行目标安排房间（中层）-步骤编码不能为空",false);
      receptionServiceRes_7 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_4);
      
      
      receptionServiceRes_8 = receptionServiceRes_7;
//processBranchName:正常结束 ,processBranchId:16658
        
    }
else if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("EXECUTE_TARGET_ARRANGE_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("BASIC"))){
       //elseif((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 执行目标安排房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 基层))  16659
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_9 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_5=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_5.setCheckItemCode("PERFORM_TARGET_TASK_ARRANGE_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:336157_1_16660
receptionServiceReq_5.setDiviCheckItemCode("DEPT_OKR_TARGET_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:336191_1_16660
receptionServiceReq_5.setStepNameCode("EXECUTE_TARGET_ARRANGE");//CUSTOM_CONVENTION//sourceId:336242_1_16660
  
    /*M3进入执行目标安排房间（基层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_5.getCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入执行目标安排房间（基层）-检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_5.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入执行目标安排房间（基层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_5.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入执行目标安排房间（基层）-步骤编码不能为空",false);
      receptionServiceRes_9 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_5);
      
      
      receptionServiceRes_10 = receptionServiceRes_9;
//processBranchName:正常结束 ,processBranchId:16661
        
    }
else if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("TARGET_TASK_DIV_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("BASIC"))){
       //elseif((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 目标任务分工房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 基层))  16900
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_11 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_6=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_6.setDiviCheckItemCode("DEPT_OKR_TARGET_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:340191_1_16901
receptionServiceReq_6.setStepNameCode("TARGET_TASK_DIV");//CUSTOM_CONVENTION//sourceId:340194_1_16901
  
    /*M3进入目标任务分工房间（基层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_6.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入目标任务分工房间（基层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_6.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入目标任务分工房间（基层）-步骤编码不能为空",false);
      receptionServiceRes_11 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_6);
      
      
      receptionServiceRes_12 = receptionServiceRes_11;
//processBranchName:正常结束 ,processBranchId:16902
        
    }
else if((reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("ACHIEVE_ARRANGE_ROOM")&&reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("BASIC"))){
       //elseif((D3判断高中基层步骤值等(公共).进入步骤房间值 等于 完成安排房间 and D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 基层))  16903
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_13 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_7=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_7.setDiviCheckItemCode("DEPT_OKR_TARGET_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:339976_1_16904
receptionServiceReq_7.setStepNameCode("ACHIEVE_ARRANGE");//CUSTOM_CONVENTION//sourceId:339977_1_16904
  
    /*M3进入完成安排房间（基层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_7.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入完成安排房间（基层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_7.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入完成安排房间（基层）-步骤编码不能为空",false);
      receptionServiceRes_13 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_7);
      
      
      receptionServiceRes_14 = receptionServiceRes_13;
//processBranchName:正常结束 ,processBranchId:16905
        
    }
else if((reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("TOP")&&reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("TARGET_TASK_DIV_ROOM"))){
       //elseif((D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 高层 and D3判断高中基层步骤值等(公共).进入步骤房间值 等于 目标任务分工房间))  16906
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_15 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_8=new ImplementBizConstructAccessParameterFieldReqDto();
receptionServiceReq_8.setStepNameCode("TARGET_TASK_DIV");//CUSTOM_CONVENTION//sourceId:340185_1_16907
  
    /*M3进入目标任务分工房间（高层）[4518]  用于特殊方法接收上游入参。 */
Assert.isNull(receptionServiceReq_8.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入目标任务分工房间（高层）-步骤编码不能为空",false);
      receptionServiceRes_15 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_8);
      
      
      receptionServiceRes_16 = receptionServiceRes_15;
//processBranchName:正常结束 ,processBranchId:16908
        
    }
else if((reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("TOP")&&reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("PALN_COMPILE_ACHIEVE_ROOM"))){
       //elseif((D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 高层 and D3判断高中基层步骤值等(公共).进入步骤房间值 等于 规划编制完成房间))  16909
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_17 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_9=new ImplementBizConstructAccessParameterFieldReqDto();
receptionServiceReq_9.setStepNameCode("PALN_COMPILE_ACHIEVE");//CUSTOM_CONVENTION//sourceId:339887_1_16910
  
    /*M3进入规划编制完成房间（高层）[4518]  用于特殊方法接收上游入参。 */
Assert.isNull(receptionServiceReq_9.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入规划编制完成房间（高层）-步骤编码不能为空",false);
      receptionServiceRes_17 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_9);
      
      
      receptionServiceRes_18 = receptionServiceRes_17;
//processBranchName:正常结束 ,processBranchId:16911
        
    }
else if((reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("MID")&&reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("TARGET_TASK_DIV_ROOM"))){
       //elseif((D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 中层 and D3判断高中基层步骤值等(公共).进入步骤房间值 等于 目标任务分工房间))  16912
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_19 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_10=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_10.setDiviCheckItemCode("DEPT_TARGET_TASK_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:340187_1_16913
receptionServiceReq_10.setStepNameCode("TARGET_TASK_DIV");//CUSTOM_CONVENTION//sourceId:340189_1_16913
  
    /*M3进入目标任务分工房间（中层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_10.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入目标任务分工房间（中层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_10.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入目标任务分工房间（中层）-步骤编码不能为空",false);
      receptionServiceRes_19 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_10);
      
      
      receptionServiceRes_20 = receptionServiceRes_19;
//processBranchName:正常结束 ,processBranchId:16914
        
    }
else if((reqDto!= null&&  reqDto.getBatchOperateScene() !=null && reqDto.getBatchOperateScene().equals("MID")&&reqDto!= null&&  reqDto.getStepRoomValue() !=null && reqDto.getStepRoomValue().equals("ACHIEVE_ARRANGE_ROOM"))){
       //elseif((D3判断高中基层步骤值等(公共).高/中/基层操作场景 等于 中层 and D3判断高中基层步骤值等(公共).进入步骤房间值 等于 完成安排房间))  16915
      
//ModelCode: receptionService
        ImplementBizConstructAccessParameterFieldRespDto receptionServiceRes_21 = null;
    ImplementBizConstructAccessParameterFieldReqDto receptionServiceReq_11=new ImplementBizConstructAccessParameterFieldReqDto();
  receptionServiceReq_11.setDiviCheckItemCode("DEPT_TARGET_TASK_CHECK_ITEM");//CUSTOM_CONVENTION//sourceId:339905_1_16916
receptionServiceReq_11.setStepNameCode("ACHIEVE_ARRANGE");//CUSTOM_CONVENTION//sourceId:339908_1_16916
  
    /*M3进入完成安排房间（中层）[4518]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_11.getDiviCheckItemCode(),"D3判断高中基层步骤值等(公共)-M3进入完成安排房间（中层）-分工总检查项标识不能为空",false);
Assert.isNull(receptionServiceReq_11.getStepNameCode(),"D3判断高中基层步骤值等(公共)-M3进入完成安排房间（中层）-步骤编码不能为空",false);
      receptionServiceRes_21 = nbInterfaceMode.implementBizConstructAccessParameterField(receptionServiceReq_11);
      
      
      receptionServiceRes_22 = receptionServiceRes_21;
//processBranchName:正常结束 ,processBranchId:16917

    }
JudgeResetTopMidStepValueComRespDto retData = new JudgeResetTopMidStepValueComRespDto();
if(receptionServiceRes_6!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_6.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setCheckItemCode(receptionServiceRes_6.getCheckItemCode());//SimpleFieldAssign//sourceId:336244_1
retData.setStepNameCode(receptionServiceRes_6.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_8!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_8.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setCheckItemCode(receptionServiceRes_8.getCheckItemCode());//SimpleFieldAssign//sourceId:336244_1
retData.setStepNameCode(receptionServiceRes_8.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_22!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_22.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setStepNameCode(receptionServiceRes_22.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_10!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_10.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setCheckItemCode(receptionServiceRes_10.getCheckItemCode());//SimpleFieldAssign//sourceId:336244_1
retData.setStepNameCode(receptionServiceRes_10.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_14!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_14.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setStepNameCode(receptionServiceRes_14.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_20!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_20.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setStepNameCode(receptionServiceRes_20.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_12!=null){
      retData.setDiviCheckItemCode(receptionServiceRes_12.getDiviCheckItemCode());//SimpleFieldAssign//sourceId:336245_1
retData.setStepNameCode(receptionServiceRes_12.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_2!=null){
      retData.setStepNameCode(receptionServiceRes_2.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_4!=null){
      retData.setStepNameCode(receptionServiceRes_4.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_18!=null){
      retData.setStepNameCode(receptionServiceRes_18.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }
if(receptionServiceRes_16!=null){
      retData.setStepNameCode(receptionServiceRes_16.getStepNameCode());//SimpleFieldAssign//sourceId:336246_1
    }


  
  
return retData;
  }
/**
   * D3执行获取当前及下一个周期(公共)[5105]
   * gen by moon at 11/3/2022, 12:18:08 AM
   */
  @Trace(operationName = "D3执行获取当前及下一个周期(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementGetCurrentAndNextCycleComRespDto implementGetCurrentAndNextCycleCom(ImplementGetCurrentAndNextCycleComReqDto reqDto){


      ObtainGetCurrentAndNextCycleRespDto getNextCycleRes_1 =null;
//步骤0: M3获取当前及下一个周期（特殊方法） - obtainGetCurrentAndNextCycle
     //ModelCode: getNextCycle
        ObtainGetCurrentAndNextCycleRespDto getNextCycleRes = null;
    ObtainGetCurrentAndNextCycleReqDto getNextCycleReq=new ObtainGetCurrentAndNextCycleReqDto();
  if(reqDto!=null){
      getNextCycleReq.setCompareTime(reqDto.getCompareTime());//SimpleFieldAssign//sourceId:417805_1
getNextCycleReq.setCurrentCycleList(reqDto.getGetCurrentAndNextCycleList().stream().map(item -> BeanUtil.toBean(item, CurrentCycleDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:417802_1
    }

    /*M3获取当前及下一个周期（特殊方法）[5103]   */
    Assert.isNull(getNextCycleReq.getCompareTime(),"D3执行获取当前及下一个周期(公共)-M3获取当前及下一个周期（特殊方法）-比较时间不能为空",false);
      getNextCycleRes = nbInterfaceMode.obtainGetCurrentAndNextCycle(getNextCycleReq);


      getNextCycleRes_1 = getNextCycleRes;

ImplementGetCurrentAndNextCycleComRespDto retData = new ImplementGetCurrentAndNextCycleComRespDto();
  if(getNextCycleRes_1!=null){
      retData.setCurrentCycleId(getNextCycleRes_1.getCurrentCycleId());//SimpleFieldAssign//sourceId:417808_1
retData.setNextCycleId(getNextCycleRes_1.getNextCycleId());//SimpleFieldAssign//sourceId:417809_1
    }




return retData;
  }
/**
   * D3执行获取当前及上一个下一个周期(公共)[5105]
   * gen by moon at 11/7/2022, 5:39:59 AM
   */
  @Trace(operationName = "D3执行获取当前及上一个下一个周期(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementGetCurrentAndLastAndNextCycleComRespDto implementGetCurrentAndLastAndNextCycleCom(ImplementGetCurrentAndLastAndNextCycleComReqDto reqDto){


      ObtainGetCurrentAndLastAndNextCycleRespDto getLastAndNextCycleRes_1 =null;
//步骤0: M3获取当前及上一个下一个周期 - obtainGetCurrentAndLastAndNextCycle
     //ModelCode: getLastAndNextCycle
        ObtainGetCurrentAndLastAndNextCycleRespDto getLastAndNextCycleRes = null;
    ObtainGetCurrentAndLastAndNextCycleReqDto getLastAndNextCycleReq=new ObtainGetCurrentAndLastAndNextCycleReqDto();
  if(reqDto!=null){
      getLastAndNextCycleReq.setCompareTime(reqDto.getCompareTime());//SimpleFieldAssign//sourceId:417805_1
getLastAndNextCycleReq.setCurrentCycleList(reqDto.getGetCurrentAndNextCycleList().stream().map(item -> BeanUtil.toBean(item, CurrentCycleDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:417802_1
    }

    /*M3获取当前及上一个下一个周期[5103]  入参：当前时间，数据集【周期ID、周期开始时间、周期结束时间】 逻辑：根据当前时间与数据集中数据开始时间、结束时间比较，获取当前周期ID以及下一个周期ID、上一个周期ID 出参：当前周期ID、下一个周期ID、上一个周期ID */
    Assert.isNull(getLastAndNextCycleReq.getCompareTime(),"D3执行获取当前及上一个下一个周期(公共)-M3获取当前及上一个下一个周期-比较时间不能为空",false);
      getLastAndNextCycleRes = nbInterfaceMode.obtainGetCurrentAndLastAndNextCycle(getLastAndNextCycleReq);


      getLastAndNextCycleRes_1 = getLastAndNextCycleRes;

ImplementGetCurrentAndLastAndNextCycleComRespDto retData = new ImplementGetCurrentAndLastAndNextCycleComRespDto();
  if(getLastAndNextCycleRes_1!=null){
      retData.setCurrentCycleId(getLastAndNextCycleRes_1.getCurrentCycleId());//SimpleFieldAssign//sourceId:417808_1
retData.setNextCycleId(getLastAndNextCycleRes_1.getNextCycleId());//SimpleFieldAssign//sourceId:417809_1
retData.setLastCycleId(getLastAndNextCycleRes_1.getLastCycleId());//SimpleFieldAssign//sourceId:424447_1
    }




return retData;
  }
/**
   * D3-获取内存中业务字段(公共)[5343]
   * gen by moon at 12/3/2022, 8:17:58 PM
   */
  @Trace(operationName = "D3-获取内存中业务字段(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ObtainGetPublicFieldCacheComRespDto obtainGetPublicFieldCacheCom(ObtainGetPublicFieldCacheComReqDto reqDto){


      ObtainGetPublicFieldCacheRespDto getPublicFieldCacheRes_1 =null;
//步骤0: M2-获取内存中业务字段（特殊方法） - obtainGetPublicFieldCache
     //ModelCode: getPublicFieldCache
        ObtainGetPublicFieldCacheRespDto getPublicFieldCacheRes = null;
    ObtainGetPublicFieldCacheReqDto getPublicFieldCacheReq=new ObtainGetPublicFieldCacheReqDto();


    /*M2-获取内存中业务字段（特殊方法）[5342]  用于定时任务/接口执行时，获取执行所需的缓存中业务字段信息，供定时任务/接口中虚拟用况使用 */

      getPublicFieldCacheRes = nbInterfaceMode.obtainGetPublicFieldCache(getPublicFieldCacheReq);


      getPublicFieldCacheRes_1 = getPublicFieldCacheRes;

ObtainGetPublicFieldCacheComRespDto retData = new ObtainGetPublicFieldCacheComRespDto();
  if(getPublicFieldCacheRes_1!=null){
      retData.setTargetCycleContentTypeCode(getPublicFieldCacheRes_1.getTargetCycleContentTypeCode());//SimpleFieldAssign//sourceId:465549_1
retData.setTargetCycleContentId(getPublicFieldCacheRes_1.getTargetCycleContentId());//SimpleFieldAssign//sourceId:465550_1
retData.setReportType(getPublicFieldCacheRes_1.getReportType());//SimpleFieldAssign//sourceId:465554_1
retData.setReportManagementModel(getPublicFieldCacheRes_1.getReportManagementModel());//SimpleFieldAssign//sourceId:465555_1
retData.setIsOpenCustomReport(getPublicFieldCacheRes_1.getIsOpenCustomReport());//SimpleFieldAssign//sourceId:465641_1
retData.setCycleId(getPublicFieldCacheRes_1.getCycleId());//SimpleFieldAssign//sourceId:465551_1
retData.setCycleTypeCode(getPublicFieldCacheRes_1.getCycleTypeCode());//SimpleFieldAssign//sourceId:465645_1
retData.setCycleStartTime(getPublicFieldCacheRes_1.getCycleStartTime());//SimpleFieldAssign//sourceId:465552_1
retData.setCycleEndTime(getPublicFieldCacheRes_1.getCycleEndTime());//SimpleFieldAssign//sourceId:465553_1
retData.setLastCycleType(getPublicFieldCacheRes_1.getLastCycleType());//SimpleFieldAssign//sourceId:465611_1
retData.setFatherCycleType(getPublicFieldCacheRes_1.getFatherCycleType());//SimpleFieldAssign//sourceId:465612_1
retData.setMidCycleType(getPublicFieldCacheRes_1.getMidCycleType());//SimpleFieldAssign//sourceId:465613_1
retData.setSubcycleType(getPublicFieldCacheRes_1.getSubcycleType());//SimpleFieldAssign//sourceId:465614_1
retData.setIrregularCycleType(getPublicFieldCacheRes_1.getIrregularCycleType());//SimpleFieldAssign//sourceId:465615_1
retData.setTargetId(getPublicFieldCacheRes_1.getTargetId());//SimpleFieldAssign//sourceId:465556_1
retData.setEvaluationTemplateId(getPublicFieldCacheRes_1.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:465557_1
retData.setSpaceId(getPublicFieldCacheRes_1.getSpaceId());//SimpleFieldAssign//sourceId:465558_1
retData.setSubjectiveScorePoint(getPublicFieldCacheRes_1.getSubjectiveScorePoint());//SimpleFieldAssign//sourceId:468823_1
retData.setDecimalDigitsLastRules(getPublicFieldCacheRes_1.getDecimalDigitsLastRules());//SimpleFieldAssign//sourceId:468824_1
retData.setCurSubjectiveScoreWeight(getPublicFieldCacheRes_1.getCurSubjectiveScoreWeight());//SimpleFieldAssign//sourceId:468825_1
retData.setProcessSubjectiveScoreWeight(getPublicFieldCacheRes_1.getProcessSubjectiveScoreWeight());//SimpleFieldAssign//sourceId:468826_1
retData.setSubjectiveScoreCountRule(getPublicFieldCacheRes_1.getSubjectiveScoreCountRule());//SimpleFieldAssign//sourceId:469012_1
retData.setDecimalPointRules(getPublicFieldCacheRes_1.getDecimalPointRules());//SimpleFieldAssign//sourceId:469869_1
retData.setWeightDecimalPoint(getPublicFieldCacheRes_1.getWeightDecimalPoint());//SimpleFieldAssign//sourceId:470647_1
retData.setDegreeDecimalPoint(getPublicFieldCacheRes_1.getDegreeDecimalPoint());//SimpleFieldAssign//sourceId:470648_1
retData.setProgressDecimalPoint(getPublicFieldCacheRes_1.getProgressDecimalPoint());//SimpleFieldAssign//sourceId:470649_1
retData.setTargetValueType(getPublicFieldCacheRes_1.getTargetValueType());//SimpleFieldAssign//sourceId:470717_1
retData.setTargetDivisionSame(getPublicFieldCacheRes_1.getTargetDivisionSame());//SimpleFieldAssign//sourceId:470718_1
retData.setLevelNumber(getPublicFieldCacheRes_1.getLevelNumber());//SimpleFieldAssign//sourceId:470719_1
retData.setQuantityObjectiveNoValue(getPublicFieldCacheRes_1.getQuantityObjectiveNoValue());//SimpleFieldAssign//sourceId:471187_1
retData.setIsSubjectiveScoring(getPublicFieldCacheRes_1.getIsSubjectiveScoring());//SimpleFieldAssign//sourceId:471481_1
retData.setSubjectiveRatingTotalValueUnit(getPublicFieldCacheRes_1.getSubjectiveRatingTotalValueUnit());//SimpleFieldAssign//sourceId:472364_1
retData.setSubjectiveRatingTotalValue(getPublicFieldCacheRes_1.getSubjectiveRatingTotalValue());//SimpleFieldAssign//sourceId:472365_1
retData.setReportObjectSetCode(getPublicFieldCacheRes_1.getReportObjectSetCode());//SimpleFieldAssign//sourceId:472366_1
retData.setReportObjectSetCode(getPublicFieldCacheRes_1.getReportObjectSetCode());//SimpleFieldAssign//sourceId:472367_1
retData.setIsParentCycle(getPublicFieldCacheRes_1.getIsParentCycle());//SimpleFieldAssign//sourceId:473044_1
retData.setIsSubCycle(getPublicFieldCacheRes_1.getIsSubCycle());//SimpleFieldAssign//sourceId:473045_1
retData.setIsMetaphase(getPublicFieldCacheRes_1.getIsMetaphase());//SimpleFieldAssign//sourceId:473046_1
retData.setIsProcessCycleStage(getPublicFieldCacheRes_1.getIsProcessCycleStage());//SimpleFieldAssign//sourceId:473047_1
retData.setIsDefinedExecuteCycleStage(getPublicFieldCacheRes_1.getIsDefinedExecuteCycleStage());//SimpleFieldAssign//sourceId:473048_1
retData.setSchemeDataPara(getPublicFieldCacheRes_1.getSchemeDataPara());//SimpleFieldAssign//sourceId:482868_1
    }




return retData;
  }
/**
   * D3-查询找祖先列表(公共)[5833]
   * gen by moon at 2/6/2023, 12:27:05 AM
   */
  @Trace(operationName = "D3-查询找祖先列表(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryLookAncestorNodeListComRespDto queryLookAncestorNodeListCom(QueryLookAncestorNodeListComReqDto reqDto){


      QueryLookAncestorNodeListRespDto findAllLevelCodeListRes_1 =null;
//步骤0: M-公共查询找祖先列表（特殊方法） - queryLookAncestorNodeList
     //ModelCode: findAllLevelCodeList
        QueryLookAncestorNodeListRespDto findAllLevelCodeListRes = null;
    QueryLookAncestorNodeListReqDto findAllLevelCodeListReq=new QueryLookAncestorNodeListReqDto();
  if(reqDto!=null){
      findAllLevelCodeListReq.setComCode(reqDto.getComCode());//SimpleFieldAssign//sourceId:646884_1
    }

    /*M-公共查询找祖先列表（特殊方法）[4799]  找入参条件的所有层级列表 */
    Assert.isNull(findAllLevelCodeListReq.getComCode(),"D3-查询找祖先列表(公共)-M-公共查询找祖先列表（特殊方法）-通用编码标识不能为空",false);
      findAllLevelCodeListRes = nbInterfaceMode.queryLookAncestorNodeList(findAllLevelCodeListReq);


      findAllLevelCodeListRes_1 = findAllLevelCodeListRes;

QueryLookAncestorNodeListComRespDto retData = new QueryLookAncestorNodeListComRespDto();
  if(findAllLevelCodeListRes_1!=null){
      retData.setLookAncestorNodeList(findAllLevelCodeListRes_1.getLookAncestorNodeList());//list-field-assign//sourceId:646887_1
    }




return retData;
  }
/**
   * D3分布式解锁(公共)[7250]
   * gen by moon at 6/26/2023, 10:08:32 PM
   */
  @Trace(operationName = "D3分布式解锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementDistributedUnlockingComRespDto implementDistributedUnlockingCom(ImplementDistributedUnlockingComReqDto reqDto){


      //步骤0: M3分布式解锁 - implementDistributedUnlocking
     //ModelCode: distributedUnlocking
        ImplementDistributedUnlockingRespDto distributedUnlockingRes = null;
    ImplementDistributedUnlockingReqDto distributedUnlockingReq=new ImplementDistributedUnlockingReqDto();
  if(reqDto!=null){
      distributedUnlockingReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1064258_1
    }

    /*M3分布式解锁[7235]   */
    Assert.isNull(distributedUnlockingReq.getCommPrimaryKey(),"D3分布式解锁(公共)-M3分布式解锁-通用主键ID不能为空",false);
      distributedUnlockingRes = nbInterfaceMode.implementDistributedUnlocking(distributedUnlockingReq);




ImplementDistributedUnlockingComRespDto retData = new ImplementDistributedUnlockingComRespDto();





return retData;
  }
/**
   * D3分布式加锁(公共)[7253]
   * gen by moon at 6/26/2023, 10:09:41 PM
   */
  @Trace(operationName = "D3分布式加锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementDistributedLockingComRespDto implementDistributedLockingCom(ImplementDistributedLockingComReqDto reqDto){


      ImplementDistributedLockingRespDto distributedLockingRes_1 =null;
//步骤0: M3-执行分布式加锁（特殊服务） - implementDistributedLocking
     //ModelCode: distributedLocking
        ImplementDistributedLockingRespDto distributedLockingRes = null;
    ImplementDistributedLockingReqDto distributedLockingReq=new ImplementDistributedLockingReqDto();
  if(reqDto!=null){
      distributedLockingReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1064254_1
      distributedLockingReq.setDuration(reqDto.getDuration());
    }

    /*M3-分布式加锁[7234]   */
    Assert.isNull(distributedLockingReq.getCommPrimaryKey(),"D3分布式加锁(公共)-M3-分布式加锁-通用主键ID不能为空",false);
Assert.isNull(distributedLockingReq.getDuration(),"D3分布式加锁(公共)-M3-分布式加锁-锁定时长不能为空",false);
      distributedLockingRes = nbInterfaceMode.implementDistributedLocking(distributedLockingReq);


      distributedLockingRes_1 = distributedLockingRes;

ImplementDistributedLockingComRespDto retData = new ImplementDistributedLockingComRespDto();
  if(distributedLockingRes_1!=null){
      retData.setTureOrFalse(distributedLockingRes_1.getTureOrFalse());//SimpleFieldAssign//sourceId:1065140_1
    }




return retData;
  }
/**
   * D3分布式加等待锁(公共)[7285]
   * gen by moon at 7/5/2023, 10:41:18 PM
   */
  @Trace(operationName = "D3分布式加等待锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementDistributedWaitLockingComRespDto implementDistributedWaitLockingCom(ImplementDistributedWaitLockingComReqDto reqDto){


      AddDistributedWaitLockingRespDto distributedWaitLockingRes_1 =null;
//步骤0: M3新增分布式加等待锁 - addDistributedWaitLocking
     //ModelCode: distributedWaitLocking
        AddDistributedWaitLockingRespDto distributedWaitLockingRes = null;
    AddDistributedWaitLockingReqDto distributedWaitLockingReq=new AddDistributedWaitLockingReqDto();
  if(reqDto!=null){
      distributedWaitLockingReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1078990_1
distributedWaitLockingReq.setDuration(reqDto.getDuration());//SimpleFieldAssign//sourceId:1078991_1
    }

    /*M3新增分布式加等待锁[7286]  用于新增分布式锁，支持有上锁等待并执行 */
    Assert.isNull(distributedWaitLockingReq.getCommPrimaryKey(),"D3分布式加等待锁(公共)-M3新增分布式加等待锁-通用主键ID不能为空",false);
Assert.isNull(distributedWaitLockingReq.getDuration(),"D3分布式加等待锁(公共)-M3新增分布式加等待锁-锁定时长不能为空",false);
      distributedWaitLockingRes = nbInterfaceMode.addDistributedWaitLocking(distributedWaitLockingReq);


      distributedWaitLockingRes_1 = distributedWaitLockingRes;

ImplementDistributedWaitLockingComRespDto retData = new ImplementDistributedWaitLockingComRespDto();
  if(distributedWaitLockingRes_1!=null){
      retData.setTureOrFalse(distributedWaitLockingRes_1.getTureOrFalse());//SimpleFieldAssign//sourceId:1078995_1
    }




return retData;
  }
/**
   * D3加分布式主题锁(公共)[7462]
   * gen by moon at 5/26/2024, 11:08:11 PM
   */
  @Trace(operationName = "D3加分布式主题锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementDistributedMotifLockingComRespDto implementDistributedMotifLockingCom(ImplementDistributedMotifLockingComReqDto reqDto){


      ImplementDistributedMotifLockingRespDto distributedLockingRes_1 =null;
//步骤0: M3加分布式主题锁（特殊方法） - implementDistributedMotifLocking
     //ModelCode: distributedLocking
        ImplementDistributedMotifLockingRespDto distributedLockingRes = null;
    ImplementDistributedMotifLockingReqDto distributedLockingReq=new ImplementDistributedMotifLockingReqDto();
  if(reqDto!=null){
      distributedLockingReq.setRedisDataObjectCatalogue(reqDto.getRedisDataObjectCatalogue());//SimpleFieldAssign//sourceId:1819328_1
      distributedLockingReq.setDistributedLockMotif(reqDto.getDistributedLockMotif());//SimpleFieldAssign//sourceId:1142486_1
distributedLockingReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1142487_1
distributedLockingReq.setDuration(reqDto.getDuration());//SimpleFieldAssign//sourceId:1142488_1
    }

    /*M3加分布式主题锁（特殊方法）[7461]   */
Assert.isNull(distributedLockingReq.getCommPrimaryKey(),"D3加分布式主题锁(公共)-M3加分布式主题锁（特殊方法）-通用主键ID不能为空",false);
Assert.isNull(distributedLockingReq.getDuration(),"D3加分布式主题锁(公共)-M3加分布式主题锁（特殊方法）-锁定时长不能为空",false);
      distributedLockingRes = nbInterfaceMode.implementDistributedMotifLocking(distributedLockingReq);


      distributedLockingRes_1 = distributedLockingRes;

ImplementDistributedMotifLockingComRespDto retData = new ImplementDistributedMotifLockingComRespDto();
  if(distributedLockingRes_1!=null){
      retData.setTureOrFalse(distributedLockingRes_1.getTureOrFalse());//SimpleFieldAssign//sourceId:1142493_1
    }




return retData;
  }
/**
   * D3批量解分布式主题锁(公共)[7464]
   * gen by moon at 10/3/2023, 6:38:28 PM
   */
  @Trace(operationName = "D3批量解分布式主题锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementDistributedMotifUnlockingComRespDto implementDistributedMotifUnlockingCom(ImplementDistributedMotifUnlockingComReqDto reqDto){


      //步骤0: M3批量解分布式主题锁（特殊方法） - implementDistributedMotifUnlocking
     //ModelCode: distributedUnlocking
        ImplementDistributedMotifUnlockingRespDto distributedUnlockingRes = null;
    ImplementDistributedMotifUnlockingReqDto distributedUnlockingReq=new ImplementDistributedMotifUnlockingReqDto();
  if(reqDto!=null){
      distributedUnlockingReq.setDistributedLockMotif(reqDto.getDistributedLockMotif());//SimpleFieldAssign//sourceId:1142495_1
    }

    /*M3批量解分布式主题锁（特殊方法）[7463]   */

      distributedUnlockingRes = nbInterfaceMode.implementDistributedMotifUnlocking(distributedUnlockingReq);




ImplementDistributedMotifUnlockingComRespDto retData = new ImplementDistributedMotifUnlockingComRespDto();





return retData;
  }
/**
   * D3探测分布式锁(公共)[7466]
   * gen by moon at 9/30/2023, 6:18:26 PM
   */
  @Trace(operationName = "D3探测分布式锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementProbeDistributedLockComRespDto implementProbeDistributedLockCom(ImplementProbeDistributedLockComReqDto reqDto){


      ImplementProbeDistributedLockRespDto probeDistributedLockRes_1 =null;
//步骤0: M3探测分布式锁（特殊方法） - implementProbeDistributedLock
     //ModelCode: probeDistributedLock
        ImplementProbeDistributedLockRespDto probeDistributedLockRes = null;
    ImplementProbeDistributedLockReqDto probeDistributedLockReq=new ImplementProbeDistributedLockReqDto();
  if(reqDto!=null){
      probeDistributedLockReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1142499_1
    }

    /*M3探测分布式锁（特殊方法）[7465]   */
    Assert.isNull(probeDistributedLockReq.getCommPrimaryKey(),"D3探测分布式锁(公共)-M3探测分布式锁（特殊方法）-通用主键ID不能为空",false);
      probeDistributedLockRes = nbInterfaceMode.implementProbeDistributedLock(probeDistributedLockReq);


      probeDistributedLockRes_1 = probeDistributedLockRes;

ImplementProbeDistributedLockComRespDto retData = new ImplementProbeDistributedLockComRespDto();
  if(probeDistributedLockRes_1!=null){
      retData.setTureOrFalse(probeDistributedLockRes_1.getTureOrFalse());//SimpleFieldAssign//sourceId:1142502_1
    }




return retData;
  }

/**
   * D3执行并发行为主题锁(公共)[8296]
   * gen by moon at 5/26/2024, 11:08:25 PM
   */
  @Trace(operationName = "D3执行并发行为主题锁(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementConcurrentBehaviorThemeLockComRespDto implementConcurrentBehaviorThemeLockCom(ImplementConcurrentBehaviorThemeLockComReqDto reqDto){


      ImplementConcurrentBehaviorThemeLockRespDto distributedLockingRes_1 =null;
if((reqDto!= null&&  reqDto.getPreventConcurrentLockingUnlocking() !=null && reqDto.getPreventConcurrentLockingUnlocking().equals("LOCK"))) {
        //if(D3执行并发行为主题锁(公共).防并发上锁or解锁 等于 上锁)  59324

//ModelCode: distributedLocking
        ImplementConcurrentBehaviorThemeLockRespDto distributedLockingRes = null;
    ImplementConcurrentBehaviorThemeLockReqDto distributedLockingReq=new ImplementConcurrentBehaviorThemeLockReqDto();
  if(reqDto!=null){
      distributedLockingReq.setRedisDataObjectCatalogue(reqDto.getRedisDataObjectCatalogue());//SimpleFieldAssign//sourceId:1819313_1_59326
      distributedLockingReq.setBehaviorThemeLockCode(reqDto.getBehaviorThemeLockCode());//SimpleFieldAssign//sourceId:1481384_1_59326
distributedLockingReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1481378_1_59326
distributedLockingReq.setCustomField1(reqDto.getCustomField1());//SimpleFieldAssign//sourceId:1481381_1_59326
distributedLockingReq.setCustomField2(reqDto.getCustomField2());//SimpleFieldAssign//sourceId:1481382_1_59326
distributedLockingReq.setCustomField3(reqDto.getCustomField3());//SimpleFieldAssign//sourceId:1481383_1_59326
distributedLockingReq.setDuration(reqDto.getDuration());//SimpleFieldAssign//sourceId:1481379_1_59326
distributedLockingReq.setTimeUnitType(reqDto.getTimeUnitType());//SimpleFieldAssign//sourceId:1481578_1_59326
    }

    /*M3执行防并发行为主题锁（特殊方法）[8295] Redis KEY ：行为主题锁_通用主键ID_自定义字段1_自定义字段2_自定义字段3  */
    Assert.isNull(distributedLockingReq.getBehaviorThemeLockCode(),"D3执行并发行为主题锁(公共)-M3执行防并发行为主题锁（特殊方法）-行为主题锁业务数据对象不能为空",false);
Assert.isNull(distributedLockingReq.getCommPrimaryKey(),"D3执行并发行为主题锁(公共)-M3执行防并发行为主题锁（特殊方法）-通用主键ID不能为空",false);
Assert.isNull(distributedLockingReq.getDuration(),"D3执行并发行为主题锁(公共)-M3执行防并发行为主题锁（特殊方法）-锁定时长不能为空",false);
Assert.isNull(distributedLockingReq.getTimeUnitType(),"D3执行并发行为主题锁(公共)-M3执行防并发行为主题锁（特殊方法）-时间单位类型不能为空",false);
      distributedLockingRes = nbInterfaceMode.implementConcurrentBehaviorThemeLock(distributedLockingReq);


      distributedLockingRes_1 = distributedLockingRes;
if((reqDto!= null&&  reqDto.getHandlingMethodConcurrentLockFailure() !=null && reqDto.getHandlingMethodConcurrentLockFailure().equals("CONCURRENT_LOCK_FAILURE_ERROR_REPORTING")&&distributedLockingRes!= null&&  distributedLockingRes.getPreventConcurrentLockingSituations() !=null && distributedLockingRes.getPreventConcurrentLockingSituations().equals("CONCURRENT_LOCK_FAILURE"))) {
        //if((D3执行并发行为主题锁(公共).并发上锁失败处理方式 等于 并发上锁失败报错 and M3执行防并发行为主题锁（特殊方法）.防并发上锁情况 等于 并发上锁失败))  59332

//异常结束 59333
      throw new BizException("C00281","对不起，当前操作繁忙，稍后再来～。",false);
      }
      }
else if((reqDto!= null&&  reqDto.getPreventConcurrentLockingUnlocking() !=null && reqDto.getPreventConcurrentLockingUnlocking().equals("UNLOCK"))){
       //elseif(D3执行并发行为主题锁(公共).防并发上锁or解锁 等于 解锁)  59325

if((reqDto!= null&&  reqDto.getWhetherUnlockBulk() !=null && reqDto.getWhetherUnlockBulk().equals("TRUE"))) {
        //if(D3执行并发行为主题锁(公共).是否批量解锁 等于 是)  59328

//ModelCode: distributedBatchUnlock
        BatchUpdateUnlockingConcurrentBehaviorThemesRespDto distributedBatchUnlockRes = null;
    BatchUpdateUnlockingConcurrentBehaviorThemesReqDto distributedBatchUnlockReq=new BatchUpdateUnlockingConcurrentBehaviorThemesReqDto();
  if(reqDto!=null){
      distributedBatchUnlockReq.setRedisDataObjectCatalogue(reqDto.getRedisDataObjectCatalogue());//SimpleFieldAssign//sourceId:1819315_1_59330
      distributedBatchUnlockReq.setBehaviorThemeLockCode(reqDto.getBehaviorThemeLockCode());//SimpleFieldAssign//sourceId:1481601_1_59330
distributedBatchUnlockReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1481600_1_59330
distributedBatchUnlockReq.setCustomField1(reqDto.getCustomField1());//SimpleFieldAssign//sourceId:1481598_1_59330
distributedBatchUnlockReq.setCustomField2(reqDto.getCustomField2());//SimpleFieldAssign//sourceId:1481599_1_59330
    }

    /*M3批量解锁并发行为主题锁（特殊方法）[8298] Redis KEY ：行为主题锁_通用主键ID_自定义字段1_自定义字段2_自定义字段3 批量解分布式锁 */
    Assert.isNull(distributedBatchUnlockReq.getBehaviorThemeLockCode(),"D3执行并发行为主题锁(公共)-M3批量解锁并发行为主题锁（特殊方法）-行为主题锁业务数据对象不能为空",false);
      distributedBatchUnlockRes = nbInterfaceMode.batchUpdateUnlockingConcurrentBehaviorThemes(distributedBatchUnlockReq);



      }
else if((reqDto!= null&&  reqDto.getWhetherUnlockBulk() !=null && reqDto.getWhetherUnlockBulk().equals("FALSE"))){
       //elseif(D3执行并发行为主题锁(公共).是否批量解锁 等于 否)  59329

//ModelCode: distributedUnlocking
        ImplementUnlockingConcurrentBehaviorThemesRespDto distributedUnlockingRes = null;
    ImplementUnlockingConcurrentBehaviorThemesReqDto distributedUnlockingReq=new ImplementUnlockingConcurrentBehaviorThemesReqDto();
  if(reqDto!=null){
      distributedUnlockingReq.setRedisDataObjectCatalogue(reqDto.getRedisDataObjectCatalogue());//SimpleFieldAssign//sourceId:1819317_1_59331
      distributedUnlockingReq.setBehaviorThemeLockCode(reqDto.getBehaviorThemeLockCode());//SimpleFieldAssign//sourceId:1481619_1_59331
distributedUnlockingReq.setCommPrimaryKey(reqDto.getCommPrimaryKey());//SimpleFieldAssign//sourceId:1481620_1_59331
distributedUnlockingReq.setCustomField1(reqDto.getCustomField1());//SimpleFieldAssign//sourceId:1481621_1_59331
distributedUnlockingReq.setCustomField2(reqDto.getCustomField2());//SimpleFieldAssign//sourceId:1481622_1_59331
distributedUnlockingReq.setCustomField3(reqDto.getCustomField3());//SimpleFieldAssign//sourceId:1481623_1_59331
    }

    /*M3执行解锁并发行为主题锁（特殊方法）[8297] Redis KEY ：行为主题锁_通用主键ID_自定义字段1_自定义字段2_自定义字段3  */
    Assert.isNull(distributedUnlockingReq.getBehaviorThemeLockCode(),"D3执行并发行为主题锁(公共)-M3执行解锁并发行为主题锁（特殊方法）-行为主题锁业务数据对象不能为空",false);
Assert.isNull(distributedUnlockingReq.getCommPrimaryKey(),"D3执行并发行为主题锁(公共)-M3执行解锁并发行为主题锁（特殊方法）-通用主键ID不能为空",false);
      distributedUnlockingRes = nbInterfaceMode.implementUnlockingConcurrentBehaviorThemes(distributedUnlockingReq);



    }
    }
ImplementConcurrentBehaviorThemeLockComRespDto retData = new ImplementConcurrentBehaviorThemeLockComRespDto();
  if(distributedLockingRes_1!=null){
      retData.setPreventConcurrentLockingSituations(distributedLockingRes_1.getPreventConcurrentLockingSituations());//SimpleFieldAssign//sourceId:1481638_1
    }




return retData;
  }
/**
   * D3新增内存业务数据(公共)[8641]
   * gen by moon at 3/15/2024, 11:35:23 PM
   */
  @Trace(operationName = "D3新增内存业务数据(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public AddMemoryBusinessDataComRespDto addMemoryBusinessDataCom(AddMemoryBusinessDataComReqDto reqDto){


      //步骤0: M3新增内存业务数据（特殊方法） - addMemoryBusinessData
     //ModelCode: addMemoryBusinessData
        AddMemoryBusinessDataRespDto addMemoryBusinessDataRes = null;
    AddMemoryBusinessDataReqDto addMemoryBusinessDataReq=new AddMemoryBusinessDataReqDto();
  if(reqDto!=null){
      addMemoryBusinessDataReq.setDataObjectBatchCode(reqDto.getDataObjectBatchCode());//SimpleFieldAssign//sourceId:1610116_1
addMemoryBusinessDataReq.setBusinessDataObject(reqDto.getBusinessDataObject());//SimpleFieldAssign//sourceId:1610118_1
addMemoryBusinessDataReq.setIsDataList(reqDto.getIsDataList());//SimpleFieldAssign//sourceId:1610117_1
    }
if(reqDto!= null&&  reqDto.getMemoryBusinessDataList() !=null&& !CollectionUtil.isEmpty(reqDto.getMemoryBusinessDataList())){
      addMemoryBusinessDataReq.setMemoryBusinessDataList(reqDto.getMemoryBusinessDataList().stream().map(item -> BeanUtil.toBean(item, MemoryBusinessDataDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1610119_1
    }

    /*M3新增内存业务数据（特殊方法）[8639]   */
    Assert.isNull(addMemoryBusinessDataReq.getDataObjectBatchCode(),"D3新增内存业务数据(公共)-M3新增内存业务数据（特殊方法）-数据对象批次标识不能为空",false);
Assert.isNull(addMemoryBusinessDataReq.getBusinessDataObject(),"D3新增内存业务数据(公共)-M3新增内存业务数据（特殊方法）-业务数据对象不能为空",false);
Assert.isNull(addMemoryBusinessDataReq.getIsDataList(),"D3新增内存业务数据(公共)-M3新增内存业务数据（特殊方法）-是否是数据集对象不能为空",false);
      addMemoryBusinessDataRes = nbInterfaceMode.addMemoryBusinessData(addMemoryBusinessDataReq);




AddMemoryBusinessDataComRespDto retData = new AddMemoryBusinessDataComRespDto();





return retData;
  }
/**
   * D3查询内存业务数据详情(公共)[8642]
   * gen by moon at 10/23/2024, 6:40:41 PM
   */
  @Trace(operationName = "D3查询内存业务数据详情(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public QueryMemoryBusinessDataDetailComRespDto queryMemoryBusinessDataDetailCom(QueryMemoryBusinessDataDetailComReqDto reqDto){


      QueryMemoryBusinessDataDetailRespDto queryMemoryBusinessDataRes_1 =null;
//步骤0: M3查询内存业务数据详情（特殊方法） - queryMemoryBusinessDataDetail
     //ModelCode: queryMemoryBusinessData
        QueryMemoryBusinessDataDetailRespDto queryMemoryBusinessDataRes = null;
    QueryMemoryBusinessDataDetailReqDto queryMemoryBusinessDataReq=new QueryMemoryBusinessDataDetailReqDto();
  if(reqDto!=null){
      queryMemoryBusinessDataReq.setDataObjectBatchCode(reqDto.getDataObjectBatchCode());//SimpleFieldAssign//sourceId:1610124_1
queryMemoryBusinessDataReq.setBusinessDataObject(reqDto.getBusinessDataObject());//SimpleFieldAssign//sourceId:1610125_1
    }
if(reqDto!= null&&  reqDto.getMemoryBusinessResDataList() !=null&& !CollectionUtil.isEmpty(reqDto.getMemoryBusinessResDataList())){
      queryMemoryBusinessDataReq.setMemoryBusinessResDataList(reqDto.getMemoryBusinessResDataList().stream().map(item -> BeanUtil.toBean(item, MemoryBusinessResDataDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1610126_1
    }

    /*M3查询内存业务数据详情（特殊方法）[8640]   */
    Assert.isNull(queryMemoryBusinessDataReq.getDataObjectBatchCode(),"D3查询内存业务数据详情(公共)-M3查询内存业务数据详情（特殊方法）-数据对象批次标识不能为空",false);
Assert.isNull(queryMemoryBusinessDataReq.getBusinessDataObject(),"D3查询内存业务数据详情(公共)-M3查询内存业务数据详情（特殊方法）-业务数据对象不能为空",false);
      queryMemoryBusinessDataRes = nbInterfaceMode.queryMemoryBusinessDataDetail(queryMemoryBusinessDataReq);


      queryMemoryBusinessDataRes_1 = queryMemoryBusinessDataRes;

QueryMemoryBusinessDataDetailComRespDto retData = new QueryMemoryBusinessDataDetailComRespDto();
  if(queryMemoryBusinessDataRes_1!=null){
      retData.setCustomField1(queryMemoryBusinessDataRes_1.getCustomField1());//SimpleFieldAssign//sourceId:1610180_1
retData.setCustomField2(queryMemoryBusinessDataRes_1.getCustomField2());//SimpleFieldAssign//sourceId:1610181_1
retData.setCustomField3(queryMemoryBusinessDataRes_1.getCustomField3());//SimpleFieldAssign//sourceId:1610182_1
retData.setCustomField4(queryMemoryBusinessDataRes_1.getCustomField4());//SimpleFieldAssign//sourceId:1610183_1
retData.setCustomField5(queryMemoryBusinessDataRes_1.getCustomField5());//SimpleFieldAssign//sourceId:1610184_1
retData.setCustomField6(queryMemoryBusinessDataRes_1.getCustomField6());//SimpleFieldAssign//sourceId:1610185_1
retData.setCustomField7(queryMemoryBusinessDataRes_1.getCustomField7());//SimpleFieldAssign//sourceId:1610186_1
retData.setCustomField8(queryMemoryBusinessDataRes_1.getCustomField8());//SimpleFieldAssign//sourceId:1610187_1
retData.setCustomField9(queryMemoryBusinessDataRes_1.getCustomField9());//SimpleFieldAssign//sourceId:1610188_1
retData.setCustomField10(queryMemoryBusinessDataRes_1.getCustomField10());//SimpleFieldAssign//sourceId:1610189_1
retData.setCustomField11(queryMemoryBusinessDataRes_1.getCustomField11());//SimpleFieldAssign//sourceId:1610190_1
retData.setCustomField12(queryMemoryBusinessDataRes_1.getCustomField12());//SimpleFieldAssign//sourceId:1610191_1
retData.setCustomField13(queryMemoryBusinessDataRes_1.getCustomField13());//SimpleFieldAssign//sourceId:1610192_1
retData.setCustomField14(queryMemoryBusinessDataRes_1.getCustomField14());//SimpleFieldAssign//sourceId:1610193_1
retData.setCustomField15(queryMemoryBusinessDataRes_1.getCustomField15());//SimpleFieldAssign//sourceId:1610194_1
retData.setCustomField16(queryMemoryBusinessDataRes_1.getCustomField16());//SimpleFieldAssign//sourceId:1610195_1
retData.setCustomField17(queryMemoryBusinessDataRes_1.getCustomField17());//SimpleFieldAssign//sourceId:1610196_1
retData.setCustomField18(queryMemoryBusinessDataRes_1.getCustomField18());//SimpleFieldAssign//sourceId:1610197_1
retData.setCustomField19(queryMemoryBusinessDataRes_1.getCustomField19());//SimpleFieldAssign//sourceId:1610198_1
retData.setCustomField20(queryMemoryBusinessDataRes_1.getCustomField20());//SimpleFieldAssign//sourceId:1610199_1
retData.setCustomField21(queryMemoryBusinessDataRes_1.getCustomField21());//SimpleFieldAssign//sourceId:1610200_1
retData.setCustomField22(queryMemoryBusinessDataRes_1.getCustomField22());//SimpleFieldAssign//sourceId:1610201_1
retData.setCustomField23(queryMemoryBusinessDataRes_1.getCustomField23());//SimpleFieldAssign//sourceId:1610202_1
retData.setCustomField24(queryMemoryBusinessDataRes_1.getCustomField24());//SimpleFieldAssign//sourceId:1610203_1
retData.setCustomField25(queryMemoryBusinessDataRes_1.getCustomField25());//SimpleFieldAssign//sourceId:1610204_1
retData.setCustomField26(queryMemoryBusinessDataRes_1.getCustomField26());//SimpleFieldAssign//sourceId:1610205_1
retData.setCustomField27(queryMemoryBusinessDataRes_1.getCustomField27());//SimpleFieldAssign//sourceId:1610206_1
retData.setCustomField28(queryMemoryBusinessDataRes_1.getCustomField28());//SimpleFieldAssign//sourceId:1610207_1
retData.setCustomField29(queryMemoryBusinessDataRes_1.getCustomField29());//SimpleFieldAssign//sourceId:1610208_1
retData.setCustomField30(queryMemoryBusinessDataRes_1.getCustomField30());//SimpleFieldAssign//sourceId:1610209_1
retData.setCustomField31(queryMemoryBusinessDataRes_1.getCustomField31());//SimpleFieldAssign//sourceId:1610210_1
retData.setCustomField32(queryMemoryBusinessDataRes_1.getCustomField32());//SimpleFieldAssign//sourceId:1610211_1
retData.setCustomField33(queryMemoryBusinessDataRes_1.getCustomField33());//SimpleFieldAssign//sourceId:1610212_1
retData.setCustomField34(queryMemoryBusinessDataRes_1.getCustomField34());//SimpleFieldAssign//sourceId:1610213_1
retData.setCustomField35(queryMemoryBusinessDataRes_1.getCustomField35());//SimpleFieldAssign//sourceId:1610214_1
retData.setCustomField36(queryMemoryBusinessDataRes_1.getCustomField36());//SimpleFieldAssign//sourceId:1610215_1
retData.setCustomField37(queryMemoryBusinessDataRes_1.getCustomField37());//SimpleFieldAssign//sourceId:1610216_1
retData.setCustomField38(queryMemoryBusinessDataRes_1.getCustomField38());//SimpleFieldAssign//sourceId:1610217_1
retData.setCustomField39(queryMemoryBusinessDataRes_1.getCustomField39());//SimpleFieldAssign//sourceId:1610218_1
retData.setCustomField40(queryMemoryBusinessDataRes_1.getCustomField40());//SimpleFieldAssign//sourceId:1610219_1
retData.setCustomField41(queryMemoryBusinessDataRes_1.getCustomField41());//SimpleFieldAssign//sourceId:1610220_1
retData.setCustomField42(queryMemoryBusinessDataRes_1.getCustomField42());//SimpleFieldAssign//sourceId:1610221_1
retData.setCustomField43(queryMemoryBusinessDataRes_1.getCustomField43());//SimpleFieldAssign//sourceId:1610222_1
retData.setCustomField44(queryMemoryBusinessDataRes_1.getCustomField44());//SimpleFieldAssign//sourceId:1610223_1
retData.setCustomField45(queryMemoryBusinessDataRes_1.getCustomField45());//SimpleFieldAssign//sourceId:1610224_1
retData.setCustomField46(queryMemoryBusinessDataRes_1.getCustomField46());//SimpleFieldAssign//sourceId:1610225_1
retData.setCustomField47(queryMemoryBusinessDataRes_1.getCustomField47());//SimpleFieldAssign//sourceId:1610226_1
retData.setCustomField48(queryMemoryBusinessDataRes_1.getCustomField48());//SimpleFieldAssign//sourceId:1610227_1
retData.setCustomField49(queryMemoryBusinessDataRes_1.getCustomField49());//SimpleFieldAssign//sourceId:1610228_1
retData.setCustomField50(queryMemoryBusinessDataRes_1.getCustomField50());//SimpleFieldAssign//sourceId:1610229_1
retData.setCustomField51(queryMemoryBusinessDataRes_1.getCustomField51());//SimpleFieldAssign//sourceId:1853097_1
retData.setCustomField52(queryMemoryBusinessDataRes_1.getCustomField52());//SimpleFieldAssign//sourceId:1857305_1
retData.setCustomField53(queryMemoryBusinessDataRes_1.getCustomField53());//SimpleFieldAssign//sourceId:1857306_1
retData.setCustomField54(queryMemoryBusinessDataRes_1.getCustomField54());//SimpleFieldAssign//sourceId:1857307_1
retData.setCustomField55(queryMemoryBusinessDataRes_1.getCustomField55());//SimpleFieldAssign//sourceId:1857308_1
retData.setCustomField56(queryMemoryBusinessDataRes_1.getCustomField56());//SimpleFieldAssign//sourceId:1857309_1
retData.setCustomField57(queryMemoryBusinessDataRes_1.getCustomField57());//SimpleFieldAssign//sourceId:2022525_1
retData.setCustomField58(queryMemoryBusinessDataRes_1.getCustomField58());//SimpleFieldAssign//sourceId:2022526_1
retData.setCustomField59(queryMemoryBusinessDataRes_1.getCustomField59());//SimpleFieldAssign//sourceId:2022527_1
retData.setCustomField60(queryMemoryBusinessDataRes_1.getCustomField60());//SimpleFieldAssign//sourceId:2022528_1
    }




return retData;
  }
/**
   * D3通用分段查询业务数据对象(公共)[9398]
   * gen by moon at 5/29/2024, 12:33:56 PM
   */
  @Trace(operationName = "D3通用分段查询业务数据对象(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementGeneralSubsectionQueryBusinessDataComRespDto implementGeneralSubsectionQueryBusinessDataCom(ImplementGeneralSubsectionQueryBusinessDataComReqDto reqDto){


      ImplementGeneralSubsectionQueryBusinessDataRespDto subsectionQueryBusinessDataSetRes_1 =null;
//步骤0: M3执行通用分段查询业务数据对象（特殊方法） - implementGeneralSubsectionQueryBusinessData
     //ModelCode: subsectionQueryBusinessDataSet
        ImplementGeneralSubsectionQueryBusinessDataRespDto subsectionQueryBusinessDataSetRes = null;
    ImplementGeneralSubsectionQueryBusinessDataReqDto subsectionQueryBusinessDataSetReq=new ImplementGeneralSubsectionQueryBusinessDataReqDto();
  if(reqDto!=null){
      subsectionQueryBusinessDataSetReq.setBusinessDataSetTableName(reqDto.getBusinessDataSetTableName());//SimpleFieldAssign//sourceId:1736993_1
subsectionQueryBusinessDataSetReq.setDatasNum(reqDto.getDatasNum());//SimpleFieldAssign//sourceId:1736209_1
subsectionQueryBusinessDataSetReq.setOrderFieldName(reqDto.getOrderFieldName());//SimpleFieldAssign//sourceId:1738897_1
subsectionQueryBusinessDataSetReq.setOrderRule(reqDto.getOrderRule());//SimpleFieldAssign//sourceId:1738898_1
subsectionQueryBusinessDataSetReq.setBusinessDataSetPrimaryKeyName(reqDto.getBusinessDataSetPrimaryKeyName());//SimpleFieldAssign//sourceId:1736994_1
subsectionQueryBusinessDataSetReq.setLastDataObjectId(reqDto.getLastDataObjectId());//SimpleFieldAssign//sourceId:1736210_1
subsectionQueryBusinessDataSetReq.setComTimeFieldName1(reqDto.getComTimeFieldName1());//SimpleFieldAssign//sourceId:1782677_1
subsectionQueryBusinessDataSetReq.setComTimeFieldValue1(reqDto.getComTimeFieldValue1());//SimpleFieldAssign//sourceId:1782678_1
subsectionQueryBusinessDataSetReq.setComTimeFieldRule1(reqDto.getComTimeFieldRule1());//SimpleFieldAssign//sourceId:1782679_1
subsectionQueryBusinessDataSetReq.setComTimeFieldName2(reqDto.getComTimeFieldName2());//SimpleFieldAssign//sourceId:1782680_1
subsectionQueryBusinessDataSetReq.setComTimeFieldValue2(reqDto.getComTimeFieldValue2());//SimpleFieldAssign//sourceId:1782681_1
subsectionQueryBusinessDataSetReq.setComTimeFieldRule2(reqDto.getComTimeFieldRule2());//SimpleFieldAssign//sourceId:1782682_1
subsectionQueryBusinessDataSetReq.setRefCustomField1(reqDto.getRefCustomField1());//SimpleFieldAssign//sourceId:1736308_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue1(reqDto.getRefCustomFieldValue1());//SimpleFieldAssign//sourceId:1736309_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue2(reqDto.getRefCustomFieldValue2());//SimpleFieldAssign//sourceId:1736311_1
subsectionQueryBusinessDataSetReq.setRefCustomField2(reqDto.getRefCustomField2());//SimpleFieldAssign//sourceId:1736310_1
subsectionQueryBusinessDataSetReq.setRefCustomField3(reqDto.getRefCustomField3());//SimpleFieldAssign//sourceId:1736312_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue3(reqDto.getRefCustomFieldValue3());//SimpleFieldAssign//sourceId:1736313_1
subsectionQueryBusinessDataSetReq.setRefCustomField4(reqDto.getRefCustomField4());//SimpleFieldAssign//sourceId:1736314_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue4(reqDto.getRefCustomFieldValue4());//SimpleFieldAssign//sourceId:1736315_1
subsectionQueryBusinessDataSetReq.setRefCustomField5(reqDto.getRefCustomField5());//SimpleFieldAssign//sourceId:1736316_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue5(reqDto.getRefCustomFieldValue5());//SimpleFieldAssign//sourceId:1736317_1
subsectionQueryBusinessDataSetReq.setRefCustomField6(reqDto.getRefCustomField6());//SimpleFieldAssign//sourceId:1736318_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue6(reqDto.getRefCustomFieldValue6());//SimpleFieldAssign//sourceId:1736319_1
subsectionQueryBusinessDataSetReq.setRefCustomField7(reqDto.getRefCustomField7());//SimpleFieldAssign//sourceId:1736320_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue7(reqDto.getRefCustomFieldValue7());//SimpleFieldAssign//sourceId:1736321_1
subsectionQueryBusinessDataSetReq.setRefCustomField8(reqDto.getRefCustomField8());//SimpleFieldAssign//sourceId:1736322_1
subsectionQueryBusinessDataSetReq.setRefCustomFieldValue8(reqDto.getRefCustomFieldValue8());//SimpleFieldAssign//sourceId:1736323_1
    }
if(reqDto!= null&&  reqDto.getOutputBusinessDataList() !=null&& !CollectionUtil.isEmpty(reqDto.getOutputBusinessDataList())){
      subsectionQueryBusinessDataSetReq.setOutputBusinessDataList(reqDto.getOutputBusinessDataList().stream().map(item -> BeanUtil.toBean(item, OutputBusinessDataDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1748515_1
    }

    /*M3执行通用分段查询业务数据对象（特殊方法）[9399]  用于分段查询业务数据对象 */
    Assert.isNull(subsectionQueryBusinessDataSetReq.getBusinessDataSetTableName(),"D3通用分段查询业务数据对象(公共)-M3执行通用分段查询业务数据对象（特殊方法）-数据对象表名不能为空",false);
Assert.isNull(subsectionQueryBusinessDataSetReq.getDatasNum(),"D3通用分段查询业务数据对象(公共)-M3执行通用分段查询业务数据对象（特殊方法）-数据条数不能为空",false);
Assert.isNull(subsectionQueryBusinessDataSetReq.getOrderFieldName(),"D3通用分段查询业务数据对象(公共)-M3执行通用分段查询业务数据对象（特殊方法）-排序字段名不能为空",false);
Assert.isNull(subsectionQueryBusinessDataSetReq.getOrderRule(),"D3通用分段查询业务数据对象(公共)-M3执行通用分段查询业务数据对象（特殊方法）-排序规则不能为空",false);
Assert.isNull(subsectionQueryBusinessDataSetReq.getBusinessDataSetPrimaryKeyName(),"D3通用分段查询业务数据对象(公共)-M3执行通用分段查询业务数据对象（特殊方法）-数据对象主键名不能为空",false);
      subsectionQueryBusinessDataSetRes = nbInterfaceMode.implementGeneralSubsectionQueryBusinessData(subsectionQueryBusinessDataSetReq);


      subsectionQueryBusinessDataSetRes_1 = subsectionQueryBusinessDataSetRes;

ImplementGeneralSubsectionQueryBusinessDataComRespDto retData = new ImplementGeneralSubsectionQueryBusinessDataComRespDto();
  if(subsectionQueryBusinessDataSetRes_1!=null){
      retData.setBusinessDataSetList(subsectionQueryBusinessDataSetRes_1.getBusinessDataSetList().stream().map(item -> BeanUtil.toBean(item, BusinessDataSetDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1736263_1
    }




return retData;
  }


    //
}
